from test_queue import MysqlDb, RedisQueue

mydb = MysqlDb()
rq = RedisQueue('rq')
list1 = mydb.read_list("select `id` from user where level = 1")
print(list1)
# res = [i['id'] for i in ]

for i in list1:
    rq.put_r(i['id'])
